package com.server.model;

import java.net.Socket;
import java.util.concurrent.ConcurrentHashMap;
/**
 * @Author e4glet
 * 2025年3月5日
 * */

// 在线用户列表
public class OnlineUsers {
    // 使用ConcurrentHashMap存储在线用户
    private static ConcurrentHashMap<Integer, Socket> onlineUsers = new ConcurrentHashMap<>();

    // 添加用户
    public static void addUser(int userId, Socket socket) {
        onlineUsers.put(userId, socket);
    }

    // 移除用户
    public static void removeUser(int userId) {
        onlineUsers.remove(userId);
    }

    // 获取用户Socket
    public static Socket getSocket(int userId) {
        return onlineUsers.get(userId);
    }
}
